# coding=utf-8

event_map = {
    "pt.spider": {
        "BestSeller": "testing_triggerAnotherJob_steps"
    },
    "aws.emr": {
        "Spark_application:testing_triggerAnotherJob_steps": "testing_runAfterEmrJobCompleted_steps"
    }
}


def get_task(event):
    event_name = event['source']
    detail_name = event['detail']['name']
    return event_map[event_name][detail_name]